package com.plugins.server;

import java.io.IOException;

public class MsgWorker {
	
	private MQServer mqServer;

	@SuppressWarnings("static-access")
	public MsgWorker(){
		mqServer = mqServer.getServer();
	}
	
	//start do work
	public void work(String queueName, String routeKey){
		try{
			mqServer.initConnection(queueName, routeKey);
			mqServer.startConsume(queueName);
		}catch(IOException e){
		}
	}

}
